from celery import Celery

# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo.settings.dev'

celery_app = Celery('meiDuo')

celery_app.config_from_object('celery_tasks.config')

celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.send_email'])

# 启动　celery　异步方法
# 先转到　celery_tasks　所在目录
# 执行命令
"""
启动、测试：
celery -A celery_tasks.main worker -l info
守护式
启动/关闭   start/stop
celery multi start cel \
-A celery_tasks.main worker \
--pidfile=./celery_tasks/cel.pid \
-l info --logfile=./logs/celery_tasks.log

cel 为进程名, 请自定义。　cel.pid 为进程文件名　celery_tasks.log　为日志文件名，均可自定义。
关闭所有celery服务
ps auxww | grep 'celery' | awk '{print $2}' | xargs kill -9
"""

